package com.cn.rxjava;

import io.reactivex.*;
import io.reactivex.disposables.Disposable;

/**
 * Created by chenyuncong on 2018/9/10.
 */
public class HelloWorld {
    public static void main(String[] args) {
        Observable novel=Observable.create(new ObservableOnSubscribe<String>() {
            @Override
            public void subscribe(ObservableEmitter<String> emitter) throws Exception {
                emitter.onNext("连载1");
                emitter.onNext("连载2");
                emitter.onNext("连载3");
                emitter.onComplete();
            }
        });




    }
}
